/*******************************************************************/
/* @ All Rights Reserved Copyright (C) 2014 broada,Co.,Ltd.        */
/*                                                                 */
/*  NAME      = activemq_parse.h                                   */
/*  NOTE      =                                                    */
/*  DATE      = 2015/05/11 by geyh                                 */
/*******************************************************************/
#ifndef __JMS_PARSE_H_
#define __JMS_PARSE_H_

#include "frbyte_buffer.h"
#include "activemq_base_type.h"
#include "activemq_core.h"

/* 4位小头节序转到本地字节序 */
#define pntohi(p)  ((unsigned int)*((const unsigned char *)(p + 0)) << 24 | \
                    (unsigned int)*((const unsigned char *)(p + 1)) << 16 | \
                    (unsigned int)*((const unsigned char *)(p + 2)) << 8 | \
                    (unsigned int)*((const unsigned char *)(p + 3)) << 0)

int activeMQ_object_parse(Frbyte_Packet *p_st_data, Frreport_body_data *p_st_body_data, L7session_activeMQ_private *p_st_private, L7_session *p_st_session);

int openwire_messageack_detect(char *p_data, unsigned int ui_data_len, Conntrack *p_st_conn);
int openwire_messagedispatch_detect(char *p_data, unsigned int ui_data_len, Conntrack *p_st_conn);

#endif
